package com.mq.consumer;
public class Main {
 
    public static void main(String[] args) {
         
        //The queue it will consume messages from
        String queueName = "person.queue";          
        Consumer consumer;;
         
    while(true){
            consumer = new Consumer();
            System.out.println("consuming...");
      //Get's blocked while no messages are found....
            consumer.consumeMessage(queueName);
            System.out.println("after consuming...");  
        }
    }
}